package com.gzp;

import org.I0Itec.zkclient.ZkClient;
import org.apache.zookeeper.CreateMode;

public class TestCURD {

	private static final String zkServers = "127.0.0.1:2181";

	private static ZkClient zkClient = null;
	static {
		// 超时时间
		int connectionTimeout = 5000;
		int sessionTimeout = 5000;
		zkClient = new ZkClient(zkServers, sessionTimeout, connectionTimeout, new CustomSerializer());
	}

	/**
	 * 连接线程
	 * 
	 * @param args
	 * @throws Exception
	 */
	public static void main(String[] args) throws Exception {
		/**
		 * 创建一个节点。 PERSISTENT：持久的 PERSISTENT_SEQUENTIAL：持久有序的 EPHEMERAL：临时的
		 * EPHEMERAL_SEQUENTIAL：临时有序的
		 */
		String str = zkClient.create("/test", "Hello World!", CreateMode.PERSISTENT);
		System.out.println("str:" + str);
		// 查询节点的值。
//		String test = zkClient.readData("/test");
//		System.out.println("test:"+test);
		// 修改节点的值。
//		zkClient.writeData("/test", "hello");
		// 删除节点。
//		boolean flag = zkClient.delete("/test");
//		System.out.println("flag:"+flag);
	}

}
